package com.mr.example;

import java.util.UUID;

import com.mr.job.*;

public class MapReduceDemo {
    public static void main(String[] args) throws Exception {
        Job<String, String, String, Integer, String, Integer> job = new Job<>();
        job.setInputPath("src/main/resources/input/input.txt");
        job.setMapperClass(WordCountMapper.class);
        job.setReducerClass(WordCountReducer.class);
        job.setNumReduceTasks(2);

        String jobId = UUID.randomUUID().toString();
        new JobTracker().run(job, jobId);
    }
}